package cn.ipanel.bigdata.boot.source

import org.apache.spark.sql.{DataFrame, SaveMode}

/**
 * Author: lzz
 * Date: 2021/11/19 9:15
 */
trait SparkExec {

  def exec(sql: String): DataFrame
  def load: DataFrame
  def save(df: DataFrame, mode: SaveMode = SaveMode.Overwrite): Unit
}